package com.cn.kafka_consumer.consumer;

import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Service;

@Service
public class ConsumerService {

    @KafkaListener(topics = "test_topic",groupId = "test_group")
    public void receiveKafkaMq(String str) {
        System.out.println("-----------------------------------收到消息："+str);
    }
}
